from celery import Celery

sms_app = Celery(
    broker='amqp://guest@localhost//',  # 消息队列的url
    # backend='amqp://guest@localhost//',  # 将调用的结果存储到MQ中
    backend='redis://localhost:6379/5'  # 将调用的结果存储到Redis中
)

# send_task在发送的时候是不会检查tasks3.add函数是否存在的，即使为空也会发送成功，所以celery执行是可能找不到该函数报错；
# ret = sms_app.send_task('task3.add', args=[3, 4])
# sms_app.send_task('sms.send_sms', args=["13146060336", "123456"])  # for test
